package com.andnnl.pool;

import com.andnnl.pool.retry.RetryMsg;

/**
 * Created by chenss on 2021/6/23.
 */
@FunctionalInterface
public interface IRetryMsgFilter<T> {
    /**
     * 判断是否添加到重试列表
     * @param retryMsg
     * @return true:消息重新添加进队列，false:任务丢掉，不再处理
     */
    boolean filterDelayMsg(RetryMsg<T> retryMsg);

}
